package com.pingan.haofang.searchcloud.common.fetch;

import com.pingan.haofang.searchcloud.api.IndexRowData;
import com.pingan.haofang.searchcloud.api.matedata.IndexMeta;

import java.util.List;

/**
 * 流式抓取处理器
 *
 * @param <R>
 * @author luyi374
 * @date 2017年4月11日
 * @since 1.0.0
 */
public interface StreamFetchHandler<E, M extends IndexMeta, R extends IndexRowData> {

    public List<StreamFetchIterator<E, M, R>> iterator();

    public void doHandle(List<R> datas, String collectionName);
}
